package com.angus.activemq.queue;

import org.apache.activemq.ActiveMQConnectionFactory;

import javax.jms.*;

/**
 * Description :
 * Created by Angus on 2022/8/11 22:50
 */
public class JmsProduce {

    public static final String ACTIVEMQ_URL = "tcp://192.168.220.110:61616";
    public static final String QUEUE_NAME = "queue01";

    public static void main(String[] args) throws JMSException {

        //创建连接工厂,按照给定的url地址，采用默认的用户名和密码
        ActiveMQConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory(ACTIVEMQ_URL);
        //通过连接工厂，获得连接connection   +  启动
        Connection connection = activeMQConnectionFactory.createConnection();
        connection.start();


        //创建会话session
        //两个参数  第一个  事物  第二个 参数
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        //创建目的地（具体是队列的主题topic
        Destination queue = session.createQueue(QUEUE_NAME);

        //创建消息的生产者
        MessageProducer producer = session.createProducer(queue);
        //通过使用messageProduct生产消息发送到mq队列里面
        for (int i = 0; i < 3; i++) {
            //创建消息
            TextMessage textMessage = session.createTextMessage("msg ---" + i);  //理解为一个字符串
            //通过messageProducer发送给mq
            producer.send(textMessage);

        }
        //关闭资源
        producer.close();
        session.close();
        connection.close();

        System.out.println("****消息发送到mq**********");
    }
}
